<?php
/**
 * Sqlite 预定义了类 SQLiteDatabase 本实现没有使用。 
 * 这里使用的全部是过程函数。 
 * 无论是函数还是类，本实现只支持sqlite的2.x系列版本。 
 * php5.3新增扩展sqlite3用来支持3.x版本。 
 * PDO则同时支持2.x和3.x版本。
 */
class LtDbConnectionAdapterSqlite implements LtDbConnectionAdapter
{
    public function connect($connConf)
    {
        if (isset($connConf['pconnect']) && true == $connConf['pconnect'])
        {
            $func = 'sqlite_popen';
        } 
        else
        {
            $func = 'sqlite_open';
        } 
        $connConf["host"] = rtrim($connConf["host"], '\\/') . DIRECTORY_SEPARATOR;
        if(!is_dir($connConf["host"]))
        {
            if(!@mkdir($connConf["host"], 0777, true))
            {
                trigger_error("Can not create {$connConf['host']}");
            }
        }
        $error = '';
        $connResource = $func($connConf["host"] . $connConf["dbname"], 0666, $error);
        if (!$connResource)
        {
            trigger_error($error, E_USER_ERROR);
        } 
        else
        {
            return $connResource;
        } 
    } 

    public function exec($sql, $connResource)
    {
        if(empty($sql))
        {
            return 0;
        }
        sqlite_exec($connResource, $sql); 
        // echo '<pre>';
        // print_r(debug_backtrace());
        // debug_print_backtrace();
        // echo '</pre>';
        // delete from table 结果为0，原因未知。
        // 使用 delete from table where 1 能返回正确结果
        return sqlite_changes($connResource);
    } 

    public function query($sql, $connResource)
    {
        $result = sqlite_query($connResource, $sql, SQLITE_ASSOC);
        return sqlite_fetch_all($result, SQLITE_ASSOC);
    } 

    public function lastInsertId($connResource)
    {
        return sqlite_last_insert_rowid($connResource);
    } 

    public function escape($sql, $connResource)
    {
        return sqlite_escape_string($sql);
    } 
} 
